
import akshare as ak

# stock_sse_deal_daily = ak.stock_sse_deal_daily(date="20220923")
# print(stock_sse_deal_daily)

# 沪深京 A 股, 实时行情数据
# stock_zh_a_spot_em = ak.stock_zh_a_spot_em()
# stock_zh_a_spot_em.to_csv("/Users/xrxs/Documents/tt12.csv", index=False)

# 机构调研数据
# stock_jgdy_tj_em = ak.stock_jgdy_tj_em(date='20220901')
# stock_jgdy_tj_em.to_csv("/Users/xrxs/Documents/jgdy.csv", index=False)

# 股票账户统计（投资者数量）
# stock_account_statistics_em = ak.stock_account_statistics_em()
# stock_account_statistics_em.to_csv("/Users/xrxs/Documents/tzzsl.csv", index=False)

# 千股千评：机构参与股、关注指数、得分等
# stock_comment_em = ak.stock_comment_em()
# stock_comment_em.to_csv("/Users/xrxs/Documents/comment.csv", index=False)

# 北向净流入
# stock_hsgt_north_net_flow_in_em = ak.stock_hsgt_north_net_flow_in_em('深股通')
# print(stock_hsgt_north_net_flow_in_em)

# 北向个股排行
# stock_hsgt_hold_stock_em = ak.stock_hsgt_hold_stock_em(market='北向', indicator='今日排行')
# # stock_hsgt_hold_stock_em.sort_values(by='5日增持估计-市值', ascending=False)
# stock_hsgt_hold_stock_em.sort_values(by='今日增持估计-市值', ascending=False)
# stock_hsgt_hold_stock_em.to_csv("/Users/xrxs/Documents/hse1.csv", index=False)

# 北向持股统计
# stock_hsgt_stock_statistics_em = ak.stock_hsgt_stock_statistics_em(symbol='北向持股', start_date='20220920', end_date='20220923')
# print(stock_hsgt_stock_statistics_em)

# 资金流入
stock_individual_fund_flow = ak.stock_individual_fund_flow("300068", market="sz")
stock_individual_fund_flow['主力净流入-净额'].max()
stock_individual_fund_flow.to_csv("/Users/xrxs/Documents/fund111.csv", index=False)






